public interface Broker {


    public void publish(Message message, long expirationTime);

    public void subscribe(String topic, Consumer consumer);



    public void unsubscribe(String topic, Consumer consumer);

}
